package com.ql.consumer.service.impl;



import com.ql.consumer.exception.MessageException;

import java.util.List;

public interface IMessageComsumer {
	public void onReceiveMessage(String topic, String message) throws MessageException;
	public List<String> getTopics();
}
